/*
 * @Description: 
 * @Author: changqing
 * @Date: 2021-08-29 21:32:30
 * @LastEditTime: 2021-08-29 21:38:11
 * @LastEditors: changqing
 * @Usage: 
 */

// 在每次事件发生时都会产生的新的Observable，不过concatMap会等前面的Observable结束后，才会接上concat产生的的Observable

var { timer, interval } = require('rxjs'); 
var { concatMap ,take} = require('rxjs/operators');
const source1 = interval(3000);
const source2 = timer(0, 1000).pipe(take(5));

source1.pipe(
  concatMap(() => source2)
).subscribe(data => {
  console.log(data);
});
// 0
// 1
// 2
// 3
// 4
// 0
// 1
// ...